package com.ksyun.alert.constant;

/**
 * Redis常量类
 * @author Zhang
 * @date 2024-04-30
 */
public class RedisStreamConstant {
    /**
     * 立即计算所在的消费者组名称
     */
    public static final String IMMEDIATE_GROUP = "skyAlert:group:immediate";
    /**
     * 向Redis写所使用的Stream名称
     */
    public static final String STREAM_NAME = "skyAlert:stream:metrics";

    /**
     * 阻塞读时间
     */
    public static final int BLOCK_TIME = 5;

    /**
     * 实时计算规缓存key
     */
    public static final String RULE_IMMEDIATE_KEY = "sky-alert:rules:immediate_rules";

    /**
     * 定时计算规缓存key
     */
    public static final String RULE_TIMING_KEY = "sky-alert:rules:timing_rules";

    /**
     * 向Redis的Stream写json消息的key
     */
    public static final String WRITE_JSON_KEY = "metrics";
}
